package cn.tx.receive;

/**
 * 批量签收
 * @author Mxb
 * @version 1.0
 * @date 2020/10/12 22:22
 */
////批量签收
//@Component
//public class MessageReceive2 {
//    @RabbitListener(bindings = {
//            @QueueBinding(value = @Queue("queue"),
//                    key = "error",
//                    exchange = @Exchange(value = "directs"))//默认的直连交换机
//    })
//    public void receiveMessage(String content, Message message, Channel channel) throws
//            IOException {
//        System.out.println("===开始消费===");
//        //消息投递ID
//        long deliveryTag = message.getMessageProperties().getDeliveryTag();
//        System.out.println("消息投递ID:" + deliveryTag);
//        String messageId = message.getMessageProperties().getMessageId();
//        System.out.println("消息自定义ID:" + messageId);
//        if (content.equals("ABC-3")) {
//            /**
//             * 参数说明:
//             * deliveryTag 消息投递ID，要签收的投递ID 是多少
//             * multiple:是否批量签收
//             */
//            channel.basicAck(deliveryTag, true);
//            System.out.println("消息签收成功-内容为:" + content);
//        }
//        System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
//    }
//}
